package org.thanos.demo.consumer;

import com.lmax.disruptor.EventHandler;
import lombok.extern.slf4j.Slf4j;
import org.thanos.demo.entity.MessageEvent;

@Slf4j
public class MessageEventConsumer<T> implements EventHandler<MessageEvent<T>> {

    public void onEvent(MessageEvent logEvent, long seq, boolean bool) {
        log.info("topic:{}, content:{}", logEvent.getTopic(), logEvent.getContent());
    }

}